package com.datasecops.scannerservices.config;

/**
 * topic配置
 * @author: SunLingzhi
 * @time: 2022/8/1 16:56
 */

public class KafkaConfig {

/*    //测试
    public static final String TOPIC_FIRST = "first";

    //------------------------主题---------------------------
    //扫描指令
    public static final String TOPIC_INSTRUCT = "topic_instruct";
    //partitions 0：dsm > scanner 发送开始解析命令
    public static final int PARTITIONS_START = 0;
    //partitions 1：scanner > dsm 返回数据
    public static final int PARTITIONS_START_CALLBACK = 1;
    //partitions 2：dsm > scanner 发送各种配置文件
    public static final int PARTITIONS_CONFIG = 2;

    //日志上传
    public static final String TOPIC_SCAN_UPLOAD = "scan_log";

    //------------------------消费者组-----------------------
    //消费者组--命令相关
    public static final String group_instruct = "group_instruct";
    public static final String group_instruct_0 = "group_instruct_0";
    public static final String group_instruct_1 = "group_instruct_1";
    public static final String group_instruct_2 = "group_instruct_2";*/


}
